1eaa26a37daa0e3259aa7cee725787787e3333a9,mule/src/java/org/mule/routing/inbound/InboundMessageRouter.java,InboundMessageRouter,route,#UMOEvent#,60
Before Change
{
try
{
if (event.isSynchronous())
{
UMOMessage messageResult = null;
for (int i = 0; i < eventsToRoute.length; i++)
{
messageResult = send(eventsToRoute[i]);
//Update stats
if (getStatistics().isEnabled())
{
getStatistics().incrementRoutedMessage(eventsToRoute[i].getEndpoint());
}
}
return messageResult;
} else
{
synchronized (eventsToRoute)
{
for (int i = 0; i < eventsToRoute.length; i++)
{
dispatch(eventsToRoute[i]);
if (getStatistics().isEnabled())
{
getStatistics().incrementRoutedMessage(eventsToRoute[i].getEndpoint());
}
}
}
return null;
}
} catch (UMOException e)
{
After Change
UMOMessage messageResult = null;
for (int i = 0; i < eventsToRoute.length; i++)
{
if (event.isSynchronous())
{
messageResult = send(eventsToRoute[i]);
} else